package backtype.storm.transactional;

import java.util.Map;

import backtype.storm.task.TopologyContext;


public interface ICommitterTransactionalSpout<X> extends ITransactionalSpout<X> {
    public interface Emitter extends ITransactionalSpout.Emitter {
        void commit(TransactionAttempt attempt);
    }


    @Override
    public Emitter getEmitter(Map conf, TopologyContext context);
}
